package com.sqoop.server;

import com.sqoop.client.client.SqoopRequest;
import com.sqoop.client.client.SqoopResponse;
import com.sqoop.core.msg.Msg;

/**
 * Created by zw on 2017/11/14.
 */
public class TestProcess extends BaseProcess{
    @Override
    public void process(Msg msg) {
            if (msg instanceof SqoopRequest){
                SqoopRequest request = (SqoopRequest)msg;
                System.out.println("age is"  + request.getAge());
                SqoopResponse sqoopResponse = new SqoopResponse(request);
                sqoopResponse.setStr("test  !!!!");
                aSend(sqoopResponse);
            }
    }

    @Override
    public void init() {

    }

    @Override
    public void stop0() {

    }

    @Override
    public void pause0() {

    }
}